package org.dromara.workflow.flowable.cmd;

import cn.hutool.core.util.ObjectUtil;
import lombok.AllArgsConstructor;
import org.dromara.common.core.utils.StreamUtils;
import org.flowable.common.engine.impl.interceptor.Command;
import org.flowable.common.engine.impl.interceptor.CommandContext;
import org.flowable.engine.impl.persistence.entity.ExecutionEntity;
import org.flowable.engine.impl.persistence.entity.ExecutionEntityManager;
import org.flowable.engine.impl.util.CommandContextUtil;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import static org.dromara.workflow.common.constant.FlowConstant.LOOP_COUNTER;
import static org.dromara.workflow.common.constant.FlowConstant.NUMBER_OF_INSTANCES;



/**
 * @Author 刘武贵
 * @Date 2024/8/15 22:00
 * @Description 功能描述：串行减签
 */
/**
 * DeleteSequenceMultiInstanceCmd类实现了Command接口，用于表示删除多实例序列的命令
 * 该类实现了Command接口的Void类型方法，通过实现Command模式来分离命令的创建和执行，以达到解耦的目的
 */
@AllArgsConstructor
public class DeleteSequenceMultiInstanceCmd implements Command<Void> {

    /**
     * 当前节点审批人员id
     */
    private final String currentUserId;

    /**
     * 执行id
     */
    private final String executionId;

    /**
     * 会签人员集合KEY
     */
    private final String assigneeList;

    /**
     * 减签人员
     */
    private final List<Long> assignees;

    /**
     * 执行流程实例更新任务
     * 该方法主要用于更新流程实例中的变量，特别是处理涉及用户ID列表的变量
     * 它会根据当前用户的执行位置，更新用户ID列表，并将这些信息作为流程变量保存
     *
     * @param commandContext 命令上下文，用于获取执行实体管理器等资源
     */
    @Override
    @SuppressWarnings("unchecked")
    public Void execute(CommandContext commandContext) {
        // 通过命令上下文获取执行实体管理器
        ExecutionEntityManager executionEntityManager = CommandContextUtil.getExecutionEntityManager();
        // 通过执行实体管理器查找指定ID的执行实体
        ExecutionEntity entity = executionEntityManager.findById(executionId);
        // 设置流程变量
        // 初始化用于存储用户ID的列表
        List<Long> userIds = new ArrayList<>();
        // 获取流程实例中已有的用户ID列表变量
        List<Object> variable = (List<Object>) entity.getVariable(assigneeList);
        // 将变量中的每个元素转换为Long类型的用户ID并添加到userIds列表中
        for (Object o : variable) {
            userIds.add(Long.valueOf(o.toString()));
        }
        // 初始化一个新的用户ID列表，用于后续处理
        List<Long> userIdList = new ArrayList<>();
        // 遍历userIds，使用StreamUtils根据assignees列表查找对应的用户ID
        userIds.forEach(e -> {
            Long userId = StreamUtils.findFirst(assignees, id -> ObjectUtil.equals(id, e));
            // 如果找不到匹配的用户ID，则将当前ID添加到userIdList中
            if (userId == null) {
                userIdList.add(e);
            }
        });
        // 当前任务执行位置
        // 初始化流程循环计数器索引
        int loopCounterIndex = -1;
        // 遍历userIdList，查找当前用户的位置索引
        for (int i = 0; i < userIdList.size(); i++) {
            Long userId = userIdList.get(i);
            // 如果找到当前用户，则记录其索引
            if (currentUserId.equals(userId.toString())) {
                loopCounterIndex = i;
            }
        }
        // 创建用于更新流程实例变量的Map
        Map<String, Object> variables = new HashMap<>(16);
        // 设置实例数量变量
        variables.put(NUMBER_OF_INSTANCES, userIdList.size());
        // 设置用户ID列表变量
        variables.put(assigneeList, userIdList);
        // 设置循环计数器变量
        variables.put(LOOP_COUNTER, loopCounterIndex);
        // 更新流程实例的变量
        entity.setVariables(variables);
        return null;
    }
}
